dd748932a3572330dd679c9ea272bde07a6a8c97,hazelcast-client-new/src/main/java/com/hazelcast/client/proxy/ClientQueueProxy.java,ClientQueueProxy,offer,#E#number#TimeUnit#,131
Before Change
public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException {
Data data = getContext().getSerializationService().toData(e);
OfferRequest request = new OfferRequest(name, unit.toMillis(timeout), data);
final Boolean result = invokeInterruptibly(request);
return result;
}
After Change
}
public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException {
Data data = toData(e);
ClientMessage request = QueueOfferParameters.encode(name, data, unit.toMillis(timeout));
ClientMessage response = invokeInterruptibly(request);
BooleanResultParameters resultParameters = BooleanResultParameters.decode(response);
return resultParameters.result;